package es

import (
	"github.com/elastic/go-elasticsearch/v7"
	"sync"
)

var (
	Es  *elasticsearch.Client
	wg  sync.WaitGroup
	err error
)

func EsConfig() {
	cfg := elasticsearch.Config{
		Addresses: []string{
			"http://14.103.169.25:9200",
		},
		// ...
	}
	Es, err = elasticsearch.NewClient(cfg)
}

//func EsAdd(good []mysql.Good) {
//	for _, title := range good {
//		wg.Add(1)
//
//		go func(title mysql.Good) {
//			defer wg.Done()
//
//			// Build the request body.
//			data, err := json.Marshal(good)
//			if err != nil {
//				log.Fatalf("Error marshaling document: %s", err)
//			}
//
//			// Set up the request object.
//			req := esapi.IndexRequest{
//				Index:      "goods",
//				DocumentID: strconv.Itoa(int(title.ID)),
//				Body:       bytes.NewReader(data),
//				Refresh:    "true",
//			}
//
//			// Perform the request with the client.
//			res, err := req.Do(context.Background(), Es)
//			if err != nil {
//				log.Fatalf("Error getting response: %s", err)
//			}
//			defer res.Body.Close()
//		}(title)
//	}
//	wg.Wait()
//}
